package cn.wjssl.domain.credit.repository;

import cn.wjssl.domain.credit.model.aggregate.TradeAggregate;
import cn.wjssl.domain.credit.model.entity.CreditAccountEntity;

/**
 * 积分相关仓储
 */
public interface ICreditRepository {

    /**
     * 创建积分操作单, 更新积分账户, 推送sku支付成功mq, 更新sku单
     * @param tradeAggregate
     */
    void saveUserCreditTradeOrder(TradeAggregate tradeAggregate);

    // 根据 userId  查询积分账户余额
    CreditAccountEntity queryUserCreditAccount(String userId);
}
